package com.thp.bigdata.rjoin.findFriends;

import java.io.IOException;

import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Reducer;

public class CommonFriendsStepOneReducer extends Reducer<Text, Text, Text, Text> {
	@Override
	protected void reduce(Text friend, Iterable<Text> users, Context context)
			throws IOException, InterruptedException {
		// 好友是key
		// 传进来的数据  <好友，用户>  ： <B,A> <B,E> <B,K> <B,W> 
		// 新建StringBuffer，用于存放拥有该好友的用户们
		StringBuffer stringBuffer = new StringBuffer();
		// 遍历所有的用户，并且将用户放在stringBuffer中，以","分割
		for(Text user : users) {
			// "A,E,K,W"
			stringBuffer.append(user).append(",");
		}
		// 以好友为key,有该好友的用户们作为value传给下一个  [mapper]
		context.write(friend, new Text(stringBuffer.toString()));
	}
	
	
}
